package com.example.direct;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @author: dangwen
 * @createDate: 2020/12/6
 * 消息发布者
 * 在spring-boot-starter-amqp中，启动器自动创建初始化一个AmqpTemplate，作为访问Amqp消息服务器（MQ中间件）的客户端对象
 */
@Component
public class LogMessageSender {

    @Autowired
    private AmqpTemplate amqpTemplate;

    /**
     * 发送消息的方法
     * amqpTemplate.convertAndSend(String exchangeName, String routingKey, Object message)
     */
    public void sendMessage(String exchangeName, String routingKey, String message){
        this.amqpTemplate.convertAndSend(exchangeName, routingKey, message);
    }
}
